﻿using Msung.Core.Kafka.Integration;

namespace Msung.Core.Kafka
{
    public interface IKafkaConsumerListener
    {
        void ConsumeAsync(RecieveResult recieveResult);
    }
    public interface IKafkaConsumerListenerSync
    {
        void ConsumeAsync(RecieveResult recieveResult);
    }
}
